package process

import (
	"context"
	"github.com/lishimeng/app-starter"
	"github.com/lishimeng/go-log"
)

var globalCtx context.Context

func Setup(ctx context.Context) (err error) {

	globalCtx = ctx
	initMqttProc()

	app.GetMqtt().OnConnect(func() { // 重连时重新初始化
		initMqttProc()
	})
	return
}

func initMqttProc() {
	log.Info("startup mqtt processes")
	log.Info(globalCtx)
	// TODO
}
